package com.raymond.thread.impl.criculation;

import com.raymond.thread.manager.annotation.ManagerCirculationThread;
import com.raymond.thread.manager.annotation.ManagerThread;
import com.raymond.thread.manager.circulation.BaseCirculationMainBackupThread;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

/**
 * 短信发送线程
 *
 * @author :  raymond
 * @version :  V1.0
 * @date :  2020-09-11 10:35
 */
@ManagerCirculationThread(threadNum = "${java.circulation.num}", managerThread = @ManagerThread(threadName =
        "循环测试线程"))
@Component
public class CirculationTestThread extends BaseCirculationMainBackupThread {


    private Logger logger = LoggerFactory.getLogger(CirculationTestThread.class);


    @Override
    protected void init() {
        super.init();
        setSleep(1000);

    }

    @Override
    protected boolean executeMainBackup() {
        System.out.println("循环测试线程:" + getName());
        return true;
    }


}
